package org.mq.mymq.client.consumer;

import java.util.List;

/**
 * @ClassName MessageConsumerListener
 * @Description 数据消费监听器
 * @Author jiarong_ye
 * @Date 2025/6/28 12:18
 * @Version 1.0
 */
public interface MessageConsumeListener {
    /**
     * 默认消费处理函数
     *
     * @param consumerMessages
     * @return
     */
    ConsumeResult consume(List<ConsumeMessage> consumerMessages);
}
